fe7ffd72b299f956d03096f68ff475c393813d68,src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java,RedisStorage,triggersFired,#List#Jedis#,662

Before Change


                pipe.set(redisSchema.jobBlockedKey(job.getKey()), schedulerInstanceId);
                pipe.sadd(redisSchema.blockedJobsSet(), jobHashKey);
                pipe.sync();
            } else if(trigger.getNextFireTime() != null){
                jedis.hset(triggerHashKey, TRIGGER_NEXT_FIRE_TIME, Long.toString(nextFireTime));
                logger.debug(String.format("Releasing trigger %s with next fire time %s. Setting state to WAITING.", triggerHashKey, nextFireTime));
                setTriggerState(RedisTriggerState.WAITING, (double) nextFireTime, triggerHashKey, jedis);

After Change


            trigger.triggered(calendar);

            // set the trigger state to WAITING
            final Date nextFireDate = trigger.getNextFireTime();
            long nextFireTime = 0;
            if (nextFireDate != null) {
                nextFireTime = nextFireDate.getTime();
                jedis.hset(triggerHashKey, TRIGGER_NEXT_FIRE_TIME, Long.toString(nextFireTime));
                setTriggerState(RedisTriggerState.WAITING, (double) nextFireTime, triggerHashKey, jedis);